package org.example
import org.apache.spark.SparkContext
import org.apache.spark.sql.SparkSession
object data1_core2 {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession
      .builder
      .master("local[*]")
      .appName("spark")
      .getOrCreate()
    val sc = spark.sparkContext
    val data1 = sc.parallelize(List(60,90,75,88,72),1)
    val data2 = sc.makeRDD(List(72,80,75,66,95),1)

    data1.filter(_>=90).foreach(println)
    sc.stop()
  }

}
